type net/http/internal/http2.pipe
17 uses
net/http/internal/http2 (current package)
pipe.go#L16: type pipe struct {
pipe.go#L35: func (p *pipe) setBuffer(b pipeBuffer) {
pipe.go#L44: func (p *pipe) Len() int {
pipe.go#L55: func (p *pipe) Read(d []byte) (n int, err error) {
pipe.go#L87: func (p *pipe) Write(d []byte) (n int, err error) {
pipe.go#L111: func (p *pipe) CloseWithError(err error) { p.closeWithError(&p.err, err, nil) }
pipe.go#L116: func (p *pipe) BreakWithError(err error) { p.closeWithError(&p.breakErr, err, nil) }
pipe.go#L120: func (p *pipe) closeWithErrorAndCode(err error, fn func()) { p.closeWithError(&p.err, err, fn) }
pipe.go#L122: func (p *pipe) closeWithError(dst *error, err error, fn func()) {
pipe.go#L148: func (p *pipe) closeDoneLocked() {
pipe.go#L162: func (p *pipe) Err() error {
pipe.go#L173: func (p *pipe) Done() <-chan struct{} {
server.go#L516: body *pipe // non-nil if expecting DATA frames
server.go#L2190: st.reqBody.pipe = &pipe{
server.go#L2245: body *pipe
server.go#L2449: pipe *pipe // non-nil if we have an HTTP entity message body
transport.go#L237: bufPipe pipe // buffered pipe with the flow-controlled response payload